package com.nami.logic.service;

import com.nami.gate.api.request.message.DownMsgBatchReq;
import com.nami.gate.api.request.message.DownMsgRequest;
import com.nami.logic.bo.send.DownModeConfig;

public interface DownMsgSender {


    boolean syncSendByMq(String topic, String tag, String msg);


    boolean flushOne(DownMsgRequest request, DownModeConfig config) throws Exception;


    boolean flushMore(DownMsgBatchReq req, DownModeConfig config) throws Exception;


}
